package xdu.lz.stage2_design_pattern.chapter13_producer_consume_pattern;

public class Client {
    public static void main(String[] args) throws InterruptedException {
        MessageQueue queue = new MessageQueue();
        new ProducerThread("p1",queue).start();
        new ProducerThread("p2",queue).start();
        new ProducerThread("p3",queue).start();

        new ConsumerThread("c1",queue).start();
        new ConsumerThread("c2",queue).start();

    }
}
